package com.lq.eureka;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface IStreamClient {
  public  static final String PARAM="asasa";
    @Input("in")
    SubscribableChannel  input();

    @Output("out")
    MessageChannel output();

}
